//package com.example.demo.mqtt;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.jms.annotation.JmsListener;
//import org.springframework.jms.core.JmsMessagingTemplate;
//import org.springframework.stereotype.Service;
//
//import javax.jms.Destination;
//
///**
// * @Author:lgl
// * @Description:
// * @Date:Create in 2017/11/30 .
// */
//@Service("producer")
//public class Producer {
//    @Autowired // 也可以注入JmsTemplate，JmsMessagingTemplate对JmsTemplate进行了封装
//     private JmsMessagingTemplate jmsTemplate;
//     // 发送消息，destination是发送到的队列，message是待发送的消息
//        public void sendMessage(Destination destination, final String message){
//        jmsTemplate.convertAndSend(destination, message);
//            }
//
//    @JmsListener(destination="out.queue")
//         public void consumerMessage(String text){
//                     System.out.println("从out.queue队列收到的回复报文为:"+text);
//                 }
//
//    @JmsListener(destination="out.2")
//    public void consumerMessage1(String text){
//        System.out.println("从consumer2队列收到的回复报文为:"+text);
//    }
//}
